package com.settlement.system.service;

import com.settlement.system.model.entity.KafkaConsumeRecord;
import com.baomidou.mybatisplus.extension.service.IService;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.settlement.system.model.query.KafkaConsumeRecordQuery;
import com.settlement.system.model.form.KafkaConsumeRecordForm;
import com.settlement.system.model.vo.KafkaConsumeRecordImportVo;
import java.util.List;

/**
 * <p>
 * kafka消费记录 服务类
 * </p>
 *
 * @author huangrensen
 * @since 2024-08-24
 */
public interface KafkaConsumeRecordService extends IService<KafkaConsumeRecord> {

    Page<KafkaConsumeRecord> getPage(KafkaConsumeRecordQuery queryParams);

    boolean saveKafkaConsumeRecord(KafkaConsumeRecordForm kafkaConsumeRecordForm);

    boolean checkCanConsume(String dataId);
    boolean saveData(String dataId);

    KafkaConsumeRecordForm getKafkaConsumeRecordFormData(Long id);

    boolean deleteKafkaConsumeRecord(String ids);

    void importData(List<KafkaConsumeRecordImportVo> importVos);

    List<KafkaConsumeRecordImportVo> findByIds(String idsStr);
}
